package cn.zwx.common.rocket.producer.service;

import cn.zwx.base.exception.BizWrapException;
import org.apache.rocketmq.client.exception.MQClientException;

/**
 * @author zhangwenxue
 */
public interface MqProducerService {

    /**
     * 启动生产者
     * @throws BizWrapException 业务异常
     */
    void start() ;

    /**
     * 关闭生产者
     */
    void shutDown();
}
